package com.stu.vertx.hello.vertxDemo.发布订阅;
 
import io.vertx.core.AbstractVerticle;
import io.vertx.core.eventbus.EventBus;
 
public class Send extends AbstractVerticle {
    @Override
    public void start() throws Exception {
        EventBus bus=vertx.eventBus();
        bus.publish("my.update","publish发布订阅模式，所有消费都可以收到，我怀疑是异步的，所以会sleep1000");
    }
}